//package com.example.wastewater.mq.producer;
//
//import lombok.RequiredArgsConstructor;
//import org.springframework.data.redis.core.StringRedisTemplate;
//import org.springframework.stereotype.Component;
//
//import java.util.Map;
//
//
///**
// * 水质报告消息队列生产者
// */
//@Component
//@RequiredArgsConstructor
//public class WaterDataReportProducer {
//    private final StringRedisTemplate stringRedisTemplate;
//
//    /**
//     *  发送消费队列统计
//     */
//    public void send(Map<String, String> producerMap){
//        stringRedisTemplate.opsForStream().add("wastewater:report-stream", producerMap);
//    }
//}
